package com.dtruth.kafka;

import org.apache.log4j.Logger;

import com.dtruth.kafka.consumer.ObjectConsumer;
import com.dtruth.kafka.producer.KafkaProducer;

/**
 * 
 * @author 岳海亮
 * @email yhl@feheadline.com
 * @date 2014年11月12日
 */
public class KafkaConsumerProducerDemo {
	private static Logger logger = Logger.getLogger(KafkaConsumerProducerDemo.class);
	public static void main(String[] args) {
		String topic = "topic1";
//		KafkaProducer producerThread = new KafkaProducer(topic);
//		producerThread.start();

		ObjectConsumer consumerThread = new ObjectConsumer(topic);
		consumerThread.start();
	}
}